package zero.tech.redis.topic;

import zero.tech.core.work.QueueWork;
import zero.tech.core.work.WorkQueue;


public abstract class RedisTopicProcess extends QueueWork{
	public abstract String orderType();

	public abstract void process(String message) throws Exception;

	public abstract TopicChannelType channelType();


	@Override
	public WorkQueue getWorkQueue() {
		return new WorkQueue() {
			@Override
			public long getId() {
				return channelType().getQueueId();
			}
		};
	}
}
